from fabric import Connection
from deploy_script.modules.config import SparkConf
from deploy_script.conn.connection_pool import ConnectionPool


class SparkHandler:

    def __init__(self, _spark_config):
        self.spark_config = _spark_config
        self.connection = ConnectionPool.get_conn(self.spark_config.host)

    def scp_keys(self):
        pass


if __name__ == '__main__':
    sparkconf = SparkConf.get_spark_conf_list()[0]
    sparkHander = SparkHandler(sparkconf)
    sparkHander.keys()
